package com.wxq.demo.config;


import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 采用Direct模式，需要在配置Queue的时候，指定一个键，使其和交换机绑定
 * Direct模式就相当于一对一模式，一个消息被发送者发送后，会被转发到一个绑定的消息队列中，然后被一个接受者接收
 */
@Configuration
public class SenderConf {
    @Bean
    public Queue queue() {
        return new Queue("queue");
    }

    @Bean
    public Queue queueUser() {
        return new Queue("userQueue");
    }
}
